#ifndef SCHEDULER_H
#define SCHEDULER_H

#include <QThread>
#include <QQueue>
#include <QMutex>
#include <QTcpSocket>

#include "message.h"

class Scheduler : public QThread
{
    Q_OBJECT
	
private:
	QQueue<Message *> messageQueue;
	QMutex mutex;
	
public:
    explicit Scheduler(QObject *parent = 0);
	void run();
	
	
signals:
	void eventNewCommand(const Message *);

public slots:
	void pushNewCommand(Message *);


};

#endif // SCHEDULER_H
